package com.lwq.project.activemq.listener;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

import org.apache.log4j.Logger;

/**
* @author 作者 linweiqiang
* @version 创建时间：2017年10月16日 上午9:55:10
* 类说明
*/
public class QueueMessageListener implements MessageListener {
public Logger logger = Logger.getLogger(QueueMessageListener.class);

	public void onMessage(Message message) {
		 TextMessage tm = (TextMessage) message;
		  try {
		   logger.error("QueueMessageListener监听到了文本消息：\t"
		     + tm.getText());
		   //do something ...
		  } catch (JMSException e) {
		   e.printStackTrace();
		  }
	}

}
